package 在线聊天室;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 在线聊天室：服务器端
 * 目标：实现一个客户可以正常收发信息
 */
public class Chat {
    public static void main(String[] args) throws IOException {
        System.out.println("-----------Server------------");
        //1.指定端口，打开一个服务端
        ServerSocket chat = new ServerSocket(8888);
        //2.阻塞式接收accept()
        Socket socket = chat.accept();
        System.out.println("一个客户端建立了连接");
        //3.接收消息
        DataInputStream dis = new DataInputStream(socket.getInputStream());
        String mag = dis.readUTF();
        System.out.println(mag);
        //4.返回消息
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        dos.writeUTF(mag);
        dos.flush();
        //5.关闭、释放资源
        chat.close();
        socket.close();
        dis.close();
        dos.close();
    }
}
